package com.wuba.rxjavademo.lyz.day0429;

import com.wuba.rxjavademo.lyz.BaseDemo;

import rx.Observable;
import rx.Subscriber;


/**
 * Created by liyaxing on 2016/5/19.
 */
public class Demo03 extends BaseDemo {


    public static void main(String[] ss){

        Observable<Integer> originObservable = Observable.just(1,2,3) ;
        Observable.Operator<Integer,String> operator = new Observable.Operator<Integer, String>() {
            @Override
            public Subscriber<? super String> call(Subscriber<? super Integer> subscriber) {

                Subscriber newS = new Subscriber() {
                    @Override
                    public void onCompleted() {

                    }

                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onNext(Object o) {

                    }
                } ;

                return null;
            }
        } ;

    }

}
